package com.example.receive.service;

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Service;

@Service
public class RabbitmqDriectConsume {


    @RabbitListener(queues = "direct_queue_1")
    public void queueDirect1(String val) {
        System.out.println("queueDirect1 " + val);
    }

    @RabbitListener(queues = "direct_queue_2")
    public void queueDirect2(String val) {
        System.out.println("queueDirect2 " + val);
    }


}
